org.springframework.core.io.buffer

Class DataBufferUtils.AsynchronousFileChannelWriteCompletionHandler

java.lang.Object

<any>

org.springframework.core.io.buffer.DataBufferUtils.AsynchronousFileChannelWriteCompletionHandler

All Implemented Interfaces:

java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer>

Enclosing class:

DataBufferUtils

private static class DataBufferUtils.AsynchronousFileChannelWriteCompletionHandler
extends <any>
implements java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer>

Field Summary

Fields

Modifier and Type	Field and Description
private java.nio.channels.AsynchronousFileChannel	channel
private java.util.concurrent.atomic.AtomicBoolean	completed
private DataBuffer	dataBuffer
private java.util.concurrent.atomic.AtomicLong	position
private <any>	sink

Constructor Summary

Constructors

Constructor and Description
AsynchronousFileChannelWriteCompletionHandler(<any> sink, java.nio.channels.AsynchronousFileChannel channel, long position)

Method Summary

Modifier and Type	Method and Description
void	completed(java.lang.Integer written, java.nio.ByteBuffer byteBuffer)
void	failed(java.lang.Throwable exc, java.nio.ByteBuffer byteBuffer)
protected void	hookOnComplete()
protected void	hookOnError(java.lang.Throwable throwable)
protected void	hookOnNext(DataBuffer value)
protected void	hookOnSubscribe(Subscription subscription)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

sink

private final <any> sink

channel

private final java.nio.channels.AsynchronousFileChannel channel

completed

private final java.util.concurrent.atomic.AtomicBoolean completed

position

private final java.util.concurrent.atomic.AtomicLong position

dataBuffer

@Nullable
private DataBuffer dataBuffer

Constructor Detail

AsynchronousFileChannelWriteCompletionHandler

public AsynchronousFileChannelWriteCompletionHandler(<any> sink,
                                                     java.nio.channels.AsynchronousFileChannel channel,
                                                     long position)

Method Detail

hookOnSubscribe

protected void hookOnSubscribe(Subscription subscription)

hookOnNext

protected void hookOnNext(DataBuffer value)

hookOnError

protected void hookOnError(java.lang.Throwable throwable)

hookOnComplete

protected void hookOnComplete()

completed

public void completed(java.lang.Integer written,
                      java.nio.ByteBuffer byteBuffer)

Specified by:

completed in interface java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer>

failed

public void failed(java.lang.Throwable exc,
                   java.nio.ByteBuffer byteBuffer)

Specified by:

failed in interface java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer>